#pragma once
#include <iostream>
#include <exception>
#include <pthread.h>
#include <semaphore.h>

//线程同步机制的封装类

class locker
{
public:
    locker()
    {
        if (pthread_mutex_init(&m_mutex, NULL) != 0) //初始化
        {

            throw std::exception(); //抛出异常
        }
    }

    bool lock()
    {
        return pthread_mutex_lock(&m_mutex) == 0;
    }

    bool unlock()
    {
        return pthread_mutex_unlock(&m_mutex) == 0;
    }

    pthread_mutex_t *get()
    {
        return &m_mutex;
    }

    ~locker()
    {

        pthread_mutex_destroy(&m_mutex);
    }

private:
    pthread_mutex_t m_mutex;
};

//信号量
class cond
{
public:
    cond()
    {
        if (pthread_cond_init(&m_cond, NULL) != 0)
        {
            throw std::exception();
        }
    }

    // wait
    bool wait(pthread_mutex_t *mutex)
    {

        return pthread_cond_wait(&m_cond, mutex) == 0;
    }

    bool timewait(pthread_mutex_t *mutex, struct timespec t)
    {
        return pthread_cond_timedwait(&m_cond, mutex, &t) == 0;
    }

    bool signal()
    {
        return pthread_cond_signal(&m_cond) == 0;
    }
    //广播
    bool broadcast()
    {
        return pthread_cond_broadcast(&m_cond) == 0;
    }

    ~cond()
    {
        pthread_cond_destroy(&m_cond);
    }

private:
    pthread_cond_t m_cond;
};

class sem
{
    public:

        sem()
        {
            if(sem_init(&m_sem,0,0)!=0)
            {
                throw std::exception();
            }
        }


         sem(int num)
        {
            if(sem_init(&m_sem,0,num)!=0)
            {
                throw std::exception();
            }
        }
        ~sem()
        {
            sem_destroy(&m_sem);

        }

        //等待信号量
        bool wait()
        {
            return sem_wait(&m_sem)==0;
        }

        //增加信号量
        bool post()
        {   

            return sem_post(&m_sem)==0;
        }


    private:
        sem_t m_sem;

};